# coding: utf8

from ansibleWorker.ansibleworker import *
import random
import string

tid = "AnsibleApiPlaybook-%s-%s" % (''.join(random.sample(string.ascii_letters + string.digits, 8)),
                                            datetime.datetime.now().strftime("%Y%m%d-%H%M%S"))
playbook = "test.yml"
inventory = "127.0.0.1"
extra_vars = {}
extra_vars['clustername'] = "all"
taskname=task1
celeryTask = taskname.apply_async((tid, playbook, inventory,  extra_vars), queue=taskname)

